package com.maotai.llzhou.timetask;

import java.util.List;
import java.util.Map;

import javax.annotation.Resource;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.maotai.llzhou.service.MaotaiService;
import com.maotai.llzhou.thread.MaotaiLoginThread;
import com.maotai.llzhou.util.IPFactory;

/**
 * 登录并且将商品加入到购物车
 */
public class MaotaiQueryWuLiuLoginTask {

	@Resource(name = "maotaiService")
	private MaotaiService maotaiService;

	public void beginTask() {
		try {
			List<Map<String, Object>> list = maotaiService
					.getZhanghaoQueryWuLiuLogin();
			if (list != null && list.size() > 0) {
				// 获取alisession
					JSONArray jArray = IPFactory.getIpAndPort();
					int count = list.size();
					int countData = jArray.size();
					if (countData < count) {
						count = countData;
					}
					for (int i = 0; i < count; i++) {
						Map<String, Object> zhanghao = list.get(i);
						JSONObject jj = (JSONObject) jArray.get(i);
						String ipAndPort = jj.getString("ip") + ":"
								+ jj.getString("port");
						zhanghao.put("loginstatus", "1");
						maotaiService.updateZhanghaoLoginStatus(zhanghao);
						zhanghao.put("day", "0");
						maotaiService.updateZhanghaoOrderItemUpdateTime(zhanghao);
						MaotaiLoginThread mcl = new MaotaiLoginThread(
								maotaiService, zhanghao, ipAndPort);
						mcl.start();
						Thread.sleep(1000);
					}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}
